package hn.cch.source

import org.apache.flink.api.scala.{DataSet, ExecutionEnvironment, createTypeInformation}

object SourceMain {

    def main(args: Array[String]): Unit = {
        val env = ExecutionEnvironment.getExecutionEnvironment
        val textDataSet: DataSet[String] = env.fromCollection(
            List("1,张三", "2,李四", "3,王五", "4,赵六")
        )

    }

}
